package com.wjw.rabbit.direct;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * 路由模式：direct,有路由Key
 * 生产者(发生消息)
 * RabbitMQ的访问地址：http://127.0.0.1:15672/
 * RabbitMQ的账号密码：admin/admin
 * 交换机direct_exchange已经在图形化界面中和队列queue1、queue2进行了绑定，所有无需写相关代码
 */
public class Producer {

    //所有的中间件都是基于TCP/IP协议,RabbitMQ遵循的是amqp协议
    //ip port
    public static void main(String[] args) {
        //1.创建连接工程
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");//RabbitMQ服务的IP
        factory.setPort(5672);//端口
        factory.setUsername("admin");//RabbitMQ的用户
        factory.setPassword("admin");//RabbitMQ的密码
        factory.setVirtualHost("/");//虚拟访问节点

        Connection connection = null;
        Channel channel = null;
        try {
            //2.创建连接Connection
            connection = factory.newConnection("生产者");
            //3.创建连接获取通道Channel
            channel = connection.createChannel();
            //String queueName = "queue2";//队列名称
            /**
             * 4.通过创建交换机、声明队列、绑定关系、路由Key、发生消息或接收消息
             * 声明队列参数说明：
             * 队列名称
             * 是否持久化：
             * 是否具有排他性:是否是独占独立
             * 是否自动删除：随着最后一个消费者消费信息完毕,是否把该队列自动删除
             * 携带额外的参数
             */
            String message = "Hello,RabbitMQ,direct";
            String exchangeName = "direct_exchange";
            String type = "direct";
            String routingKey = "email";
            //channel.queueDeclare(queueName,true,false,false,null);
            //5.准备消息

            /**
             * 6.通过交换机将消息发送到队列中
             * 参数说明：
             * 交换机名称
             * 队列/路由key:队列queue1绑定了key,email;队列queue2绑定了key,goods;
             * 其他参数
             * 发送的消息
             *
             * 使用key:email,queue1能收到消息。
             * 使用key:goods,queue2能收到消息。
             */
            channel.basicPublish(exchangeName,routingKey,null,message.getBytes());
            System.out.println("消息发生成功！");
        } catch (IOException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }finally {
            //7.关闭通道
            if(channel != null && channel.isOpen()){
                try {
                    channel.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            //8.关闭连接
            if(connection != null && connection.isOpen()){
                try {
                    connection.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }

    }

}
